package com.kxxnzstdsw.modle.repo.impl

import com.kxxnzstdsw.modle.entity.Metadata
import com.kxxnzstdsw.modle.repo.BasicRepository
import com.kxxnzstdsw.modle.repo.MetadataRepository
import org.babyfish.jimmer.sql.ast.mutation.SaveMode
import org.babyfish.jimmer.sql.kt.KSqlClient
import java.sql.Connection

class MetadataRepositoryImpl(override val sqlClient: KSqlClient) : MetadataRepository, BasicRepository() {
  override suspend fun save(metadata: Metadata) {
    sqlClient.save(metadata, SaveMode.INSERT_ONLY)
  }

  override suspend fun saveAll(vararg metadata: Metadata, conn: Connection?) {
    sqlClient.entities.saveEntities(metadata.toList(), conn)
  }
}
